package com.z.demo.filter
import org.apache.commons.lang3.StringUtils
import org.apache.flink.api.common.functions.FilterFunction
/**
 * @Author wenz.ma
 * @Date 2021/10/26 13:44
 * @Desc 简单实现一个过滤空数据的过滤器
 */
object NullFilter extends FilterFunction[String]{
  override def filter(value: String): Boolean = {
    //判断是否为null,或者空字符串""
    if(StringUtils.isEmpty(value)){
      false //false 的数据不传递到下一个算子
    }else{
      true
    }
  }
}
